| kafka 日志收集器实战 | 您所在的位置：网站首页 › kafka 日志收集 › kafka 日志收集器实战 |
kafka 日志收集器实战
|
一、需求
使用Kafka做日志收集 1、参考kafka学习 一文搭建相关得zookeeper集群与kafka集群。 2、根据ngx_kafka_module网址：https://github.com/brg-liuwei/ngx_kafka_module上得教程搭建nginx配置相关得日志接口。 4、在前端封装用户得操作，比如点击了某个按钮，收藏了哪个商品等等，触发这些操作后发送post请求到我们所监听得请求地址。 function sendLog(action,job_code) { $.ajax({ url:log_server_addr, type:"POST", async:false, data:combine(action, job_code), dataType:"json", success:function (data) { }, error:function () { alert("失败") } }) } /*组装报文*/ function combine(act, jc) { let user_id = $.cookie("lgn_name"); let act_time = new Date().getTime(); let action = act; let job_code = jc; let result = {} result["user_id"] = user_id; result["act_time"] = act_time; result["action"] = action; if (action == 'login' || action == 'logout') { } else { if(job_code){ result["job_code"] = job_code; } } return result; }5、如下图所示，能看到一些用户得操作日志
|
3、启动nginx后，我们可以使用curl 进行测试，同时可以查看到kafka是否有收到相关得消息。 
【本文地址】
公司简介
联系我们